package com.study.djl.consumer.service;

import com.study.djl.consumer.integration.ProviderInt;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class KafkaService {

    @Resource
    private ProviderInt providerInt;

    public void hello(String name) {
        providerInt.hello().send(MessageBuilder.withPayload(name).build());
    }
}
